const mysql = require('mysql');
const { MYSQL_CONFIG } = require('../config/db');

// 创建连接
let con = mysql.createConnection(MYSQL_CONFIG);

// 开始连接
con.connect();

// 统一执行sql的函数
function exec(sql) {
    const promise = new Promise((resolve, reject) => {
        con.query(sql, (err, result) => {
            if(err) {
                console.log('db===>', err)
                reject(err);
                return
            }
            resolve(result)
        });
    });
    return promise;
}

module.exports = {
    exec,
    /**
     * 防止xss攻击的方法
     */
    escape: mysql.escape,
}




// 执行sql语句
// const sql = 'select * from user;'
// // const sql = `UPDATE user set name="mahitu" WHERE type="super_admin";`
// con.query(sql, (err, result) => {
//     if(err) {
//         console.log(err);
//         return
//     }
//     // OkPacket {
//     // fieldCount: 0,
//     // affectedRows: 0, affectedRows为1的时候说明执行成功
//     // insertId: 0,
//     // serverStatus: 34,
//     // warningCount: 0,
//     // message: '(Rows matched: 0  Changed: 0  Warnings: 0',
//     // protocol41: true,
//     // changedRows: 0 }
//     console.log(result);
// });
// // 关闭连接
// con.end()